package com.itheima.blockingqueue;

import java.util.concurrent.LinkedBlockingQueue;

public class Demo02 {

    public static void main(String[] args) throws InterruptedException {
        LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<>(3);
        queue.put("坤坤1");
        queue.put("坤坤2");
        queue.put("坤坤3");
        String take = queue.take();
        System.out.println(take);
        System.out.println(queue);
        queue.put("坤坤4");
        //put 放 元素 如果 满了 就等着
        System.out.println(queue);
        System.out.println(queue.take());
        System.out.println(queue.take());
        System.out.println(queue.take());
        System.out.println(queue.take());
        //take 取  如果集合中没有元素  就等着

    }
}
